var express = require('express');
var router = express.Router();


// 引入配置文件
const db = require('../dataBase/db')
/* GET home page. */
//    请求头  响应头  下一步
router.get('/', function (req, res, next) {
  // res.render('index', { title: 'Express' });
  res.json({ title: 'Express' })
});


// 茶叶接口
router.get('/tea', (req, res) => {
  let sql = 'select * from `tea_tea`'
  // 错误信息和数据
  db.query(sql, (err, data) => {
    // 如果信息为错误的话，返回查询失败
    if (err) {
      res.json({ msg: '查询失败', err })
      // 否则就是查询成功，然后返回数据
    }
    else {
      res.json({ msg: '查询成功', data })
    }

  })

})


// 添加
router.post('/tea', (req, res) => {
  let sql = 'insert into tea_tea (name,type,price,stock,description) values(?,?,?,?,?)'
  // 错误信息和数据
  db.query(sql, [req.body.name, req.body.type, req.body.price, req.body.stock, req.body.description],
    (err, result) => {
      // 如果信息为错误的话，返回查询失败
      if (err) {
        res.json({ msg: '添加失败', err })
        // 否则就是查询成功，然后返回数据
      }else {
        // 如果result:结果行数为一行的时候添加成功并且
        if (result.affectedRows == 1) {
          // 数据库为新插入的行自动生成的ID(如果数据库表有自增主键的话)
          res.json({ msg: '添加成功', id: result.insertId })
          // 否则添加失败
        } else {
          res.json({ msg: '添加失败' })
        }
      }
    })
})

// 删除
router.delete('/tea', (req, res) => {
  let sql = 'DELETE FROM `tea_tea` WHERE `id` = ?'
  // 错误信息和数据
  db.query(sql, [req.query.id], (err, data) => {// 这里应该使用 
    // req.query.id 或者 req.params.id 来获取要删除的 id
    // 如果信息为错误的话返回查询失败
    if (err) {
      res.json({ msg: '删除失败', err })
      // 否则就是查询成功，然后返回数据
    } else {
      // 应该返回 affectedRows
      res.json({ msg: '删除成功', data })
    }
  })

})

// 修改
router.put('/tea', (req, res) => {
  let sql = 'UPDATE tea_tea SET name = ?,type = ?,price = ?,stock = ?,description = ? WHERE id = ?'
  // 错误信息和数据
  db.query(sql, [req.body.name, req.body.type, req.body.price, req.body.stock, req.body.description,req.query.id], (err, data) => {
    // 如果信息为错误的话返回查询失败
    if (err) {
      res.json({ msg: '修改失败', err })
      // 否则就是查询成功，然后返回数据
    } else {
      res.json({ msg: '修改成功', data })
    }
  })

})

// 查询
router.get("/tea/searchTea", (req, res) => {
  let search_id = req.query.id;
  if (!search_id) {
    return res.status(400).json({ msg: "缺少查询参数 id" });
  }
  let sql = "SELECT * FROM tea_tea WHERE id=?";
  db.query(sql, [search_id], (err, data) => {
    if (err) {
      return res.status(500).json({ msg: "查询失败", err });
    } else {
      if (data.length > 0) {
        res.json({ msg: "查询成功", data });
      } else {
        res.json({ msg: "未找到数据", data: [] });
      }
    }
  });
});
module.exports = router;
